package com.yiduo.outpost.stream.listener;

import lombok.extern.slf4j.Slf4j;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Service;

@Slf4j
@Service
public class KafkaConsumer {
    /**
     * 监听"kafka"主题中的数据，并将数据存储在数据库中。
     *
     * @param message 接收到的消息内容
     */
	@KafkaListener(topics = "rds-report", groupId = "rds-report-prod")
    public void listen(String message) {
        log.info("Received Message: {}" , message);
    }
}